package com.kc.gb.device.plugins.slant.service;

import com.kc.gb.device.plugins.slant.events.support.SlantPublishEvent;
import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
import org.apache.rocketmq.client.producer.DefaultMQProducer;


public interface SlantMQService {

    void sendFeedBackMessage(SlantPublishEvent command) throws Exception;

    DefaultMQProducer createCommandProducer() throws Exception;

    DefaultMQPushConsumer createCommandConsumer() throws Exception;
}
